package br.com.utfpr.persistence;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import br.com.utfpr.modelo.Prefeito;

public class ConsultaPrefeito extends Conexao {
        
        /**
         * Consulta o estado pelo códiogo uf informado.
         * 
         * @param String - uf
         * @return Prefeito
         */
        public Prefeito consultaPrefeitoByMunicipio (int codigoIbge) {
                Prefeito prefeito = null;
                Connection con = abreConexao();
                
                try {
                        
						String sql = "SELECT candidato, partido FROM prefeitos2008 WHERE ibge = ? ;";
                        
                        PreparedStatement ps = con.prepareStatement(sql);
                        
                        ps.setInt(1, codigoIbge);
                        
                        ResultSet res = ps.executeQuery();
                        
                        if (res != null) {
                                while (res.next())      {
                                        prefeito = new Prefeito();
                                        
										prefeito.setNome(res.getString("candidato"));
										prefeito.setPartido(res.getString("partido"));
                                }
                        }
                } catch (SQLException e) {
                        System.out.println("### ERRO AO CONSULTAR O PREFEITOS ELEITO. ###");
                        e.printStackTrace();
                } finally {
                        fechaConexao(con);
                }
                
                return prefeito;
        }

}